8923feb665cd9e6ce01b8365c17987a5c26fcf7d,src/test/java/net/jodah/lyra/internal/ChannelRecoveryTest.java,ChannelRecoveryTest,mockRecovery,#Exception#,84

Before Change


    mockConsumer(2, 5);
    mockConsumer(2, 6);

    when(mockChannel(2).delegate.basicConsume(eq("test-queue"), eq(mockConsumer(2, 5)))).thenAnswer(
        failNTimes(3, e, "test-tag"));
  }
}

After Change


        failNTimes(2, e, null, mockChannel(2).channelHandler));
    when(
        mockChannel(2).delegate.basicConsume(eq("test-queue"),
            argThat(matcherFor(mockConsumer(2, 5))))).thenAnswer(
        failNTimes(3, e, "test-tag", mockChannel(2).channelHandler));
  }
}